package com.tvunetworks.center.device.schedule;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @program: tvucc-aggregator
 * @description: DeviceGeoSchedule
 * @author lebronchen
 * @create: 2020-04-20 14:46
 **/
@Component
@Slf4j
public class DeviceGeoSchedule {

//    @Autowired
//    private DeviceGeoService deviceGeoService;
//    @Autowired
//    @Qualifier("deviceChangeElection")
//    private LeaderElection leaderElection;
//    @Autowired
//    private RedisUtil redisUtil;

//    @Scheduled(initialDelayString = "2000", fixedDelayString = "${task.initDeviceGeo}")
//    public void initDeviceGeoSchedule(){
//        if (!leaderElection.isMaster()) {
//            log.info("DeviceGeoSchedule leader election not master");
//            return;
//        }
//        try {
//            deviceGeoService.initDeviceGeo();
//        } catch (Exception e) {
//            log.error(e.toString(), e);
//        }
//
//    }

//    /**
//     * 检查syncPSSchedule 是否正常执行，如果不正常执行，需要重试
//     */
//    @Scheduled(initialDelayString = "2000", fixedDelayString = "30000")
//    public void heartbeatAndRetry(){//
//        try {
//            String key = (String)redisUtil.get("heartbeatAndRetry");
//            if(StringUtils.isEmpty(key)){
//
//            }
//            deviceGeoService.initDeviceGeo();
//        } catch (Exception e) {
//            log.error(e.toString(), e);
//        }
//
//    }
}
